package com.ruoyi.control.service.impl;

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; //添加
import com.ruoyi.common.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ruoyi.control.mapper.GasDrainagePumpRoomMapper;
import com.ruoyi.control.domain.GasDrainagePumpRoom;
import com.ruoyi.control.service.IGasDrainagePumpRoomService;

/**
 * 瓦斯抽放泵房Service业务层处理
 *
 * @author ruoyi
 * @date 2024-11-08
 */
@Service
public class GasDrainagePumpRoomServiceImpl extends ServiceImpl<GasDrainagePumpRoomMapper, GasDrainagePumpRoom> implements IGasDrainagePumpRoomService //修改
{
    @Autowired
    private GasDrainagePumpRoomMapper gasDrainagePumpRoomMapper;

    /**
     * 查询瓦斯抽放泵房
     *
     * @param tagName 瓦斯抽放泵房主键
     * @return 瓦斯抽放泵房
     */
    @Override
    public GasDrainagePumpRoom selectGasDrainagePumpRoomByTagName(String tagName) {
        return gasDrainagePumpRoomMapper.selectGasDrainagePumpRoomByTagName(tagName);
    }

    /**
     * 查询瓦斯抽放泵房列表
     *
     * @param gasDrainagePumpRoom 瓦斯抽放泵房
     * @return 瓦斯抽放泵房
     */
    @Override
    public List<GasDrainagePumpRoom> selectGasDrainagePumpRoomList(GasDrainagePumpRoom gasDrainagePumpRoom) {
        return gasDrainagePumpRoomMapper.selectGasDrainagePumpRoomList(gasDrainagePumpRoom);
    }

    /**
     * 新增瓦斯抽放泵房
     *
     * @param gasDrainagePumpRoom 瓦斯抽放泵房
     * @return 结果
     */
    @Override
    public int insertGasDrainagePumpRoom(GasDrainagePumpRoom gasDrainagePumpRoom) {
        return gasDrainagePumpRoomMapper.insertGasDrainagePumpRoom(gasDrainagePumpRoom);
    }

    /**
     * 修改瓦斯抽放泵房
     *
     * @param gasDrainagePumpRoom 瓦斯抽放泵房
     * @return 结果
     */
    @Override
    public int updateGasDrainagePumpRoom(GasDrainagePumpRoom gasDrainagePumpRoom) {
        gasDrainagePumpRoom.setUpdateTime(DateUtils.getNowDate());
        return gasDrainagePumpRoomMapper.updateGasDrainagePumpRoom(gasDrainagePumpRoom);
    }

    /**
     * 批量删除瓦斯抽放泵房
     *
     * @param tagNames 需要删除的瓦斯抽放泵房主键
     * @return 结果
     */
    @Override
    public int deleteGasDrainagePumpRoomByTagNames(String[] tagNames) {
        return gasDrainagePumpRoomMapper.deleteGasDrainagePumpRoomByTagNames(tagNames);
    }

    /**
     * 删除瓦斯抽放泵房信息
     *
     * @param tagName 瓦斯抽放泵房主键
     * @return 结果
     */
    @Override
    public int deleteGasDrainagePumpRoomByTagName(String tagName) {
        return gasDrainagePumpRoomMapper.deleteGasDrainagePumpRoomByTagName(tagName);
    }

    @Override
    public List<GasDrainagePumpRoom> gasValueList() {
//        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.selectGasDrainagePumpRoomList(null);

        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();


        //ABC绕相 数据     电压、电流、功率 多个 不知道对应那个   BDJAXWD_1  BDJBXWD_1  BDJCXWD_1   BDJABXDY_1  BDJAXDL_1  BDJGL_1
        List<String> tagNames = Arrays.asList("BDJQZWD_1", "BDJHZWD_1", "BDJAXWD_1", "BDJBXWD_1", "BDJCXWD_1", "BBTQZWD_1", "BBTHZWD_1", "BDJABXDY_1", "BDJAXDL_1", "BDJGL_1",
                "BDJQZWD_2", "BDJHZWD_2", "BDJAXWD_2", "BDJBXWD_2", "BDJCXWD_2", "BBTQZWD_2", "BBTHZWD_2", "BDJABXDY_2", "BDJAXDL_2", "BDJGL_2",
                "BDJQZWD_3", "BDJHZWD_3", "BDJAXWD_3", "BDJBXWD_3", "BDJCXWD_3", "BBTQZWD_3", "BBTHZWD_3", "BDJABXDY_3", "BDJAXDL_3", "BDJGL_3",
                "BDJQZWD_4", "BDJHZWD_4", "BDJAXWD_4", "BDJBXWD_4", "BDJCXWD_4", "BBTQZWD_4", "BBTHZWD_4", "BDJABXDY_4", "BDJAXDL_4", "BDJGL_4");


        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasWaterValue() {

        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        List<String> tagNames = Arrays.asList("DSCSWei", "DSCSWen", "GSCSWei", "GSCSWen");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasGasValue() {


        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //工况流量  GFYGLHHLL
        List<String> tagNames = Arrays.asList("GFYGLGDJW", "GFYGLGDWD", "GFYGLGDFY", "GFYGLHHLL", "GFYGLBKLL", "GFYGLYYHT",
                "DFYGLGDJW", "DFYGLGDWD", "DFYGLGDFY", "GFYGLHHLL", "DFYGLBKLL", "DFYGLYYHT");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> getHJWSWD() {


        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //环境瓦斯、温度
        List<String> tagNames = Arrays.asList("HJJW1", "HJWD1");

        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> getWaterStatus() {

        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //供水状态、远控、就地、检修
        List<String> tagNames = Arrays.asList("BQSBJ_1", "BYKMS_1", "BJDMS_1", "BJXMS_1",
                "BQSBJ_2", "BYKMS_2", "BJDMS_2", "BJXMS_2",
                "BQSBJ_3", "BYKMS_3", "BJDMS_3", "BJXMS_3",
                "BQSBJ_4", "BYKMS_4", "BJDMS_4", "BJXMS_4");

        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> getFyValue() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();


        //泵负压
        List<String> tagNames = Arrays.asList("BFY_1", "BFY_2", "BFY_3", "BFY_4");

        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> getWaterState() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        List<String> tagNames = Arrays.asList("BQSBJ_1", "BYKMS_1", "BJDMS_1", "BJXMS_1",
                "BQSBJ_2", "BYKMS_2", "BJDMS_2", "BJXMS_2",
                "BQSBJ_3", "BYKMS_3", "BJDMS_3", "BJXMS_3",
                "BQSBJ_4", "BYKMS_4", "BJDMS_4", "BJXMS_4");

        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> getGasValueList() {
        return gasDrainagePumpRoomMapper.getGasValueList();
    }

    @Override
    public List<GasDrainagePumpRoom> gasDyValueListOne() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //1、2、5、6  泵  电机前轴、后轴、绕组A、B/C 电压、电流、泵真空度
        List<String> tagNames = Arrays.asList("ws_pump1_wd_dj_qz", "ws_pump1_wd_dj_hz", "ws_pump1_wd_dj_A", "ws_pump1_wd_dj_B", "ws_pump1_wd_dj_C", "ws_pump1_Uab_out", "ws_pump1_Ia_out", "泵真空度1",
                "ws_pump2_wd_dj_qz", "ws_pump2_wd_dj_hz", "ws_pump2_wd_dj_A", "ws_pump2_wd_dj_B", "ws_pump2_wd_dj_C", "ws_pump2_Uab_out", "ws_pump2_Ia_out", "泵真空度2",
                "ws_pump5_wd_dj_qz", "ws_pump5_wd_dj_hz", "ws_pump5_wd_dj_A", "ws_pump5_wd_dj_B", "ws_pump5_wd_dj_C", "ws_pump5_Uab_out", "ws_pump5_Ia_out", "泵真空度5",
                "ws_pump6_wd_dj_qz", "ws_pump6_wd_dj_hz", "ws_pump6_wd_dj_A", "ws_pump6_wd_dj_B", "ws_pump6_wd_dj_C", "ws_pump6_Uab_out", "ws_pump6_Ia_out", "泵真空度6");


        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasDyValueListTwo() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //7、8、9、10  泵  电机前轴、后轴、绕组A、B/C 电压、电流、泵真空度
        List<String> tagNames = Arrays.asList("ws_pump7_wd_dj_qz", "ws_pump7_wd_dj_hz", "ws_pump7_wd_dj_A", "ws_pump7_wd_dj_B", "ws_pump7_wd_dj_C", "ws_pump7_Uab_out", "ws_pump7_Ia_out", "泵真空度7",
                "ws_pump8_wd_dj_qz", "ws_pump8_wd_dj_hz", "ws_pump8_wd_dj_A", "ws_pump8_wd_dj_B", "ws_pump8_wd_dj_C", "ws_pump8_Uab_out", "ws_pump8_Ia_out", "泵真空度8",
                "ws_pump9_wd_dj_qz", "ws_pump9_wd_dj_hz", "ws_pump9_wd_dj_A", "ws_pump9_wd_dj_B", "ws_pump9_wd_dj_C", "ws_pump9_Uab_out", "ws_pump9_Ia_out", "泵真空度9",
                "ws_pump10_wd_dj_qz", "ws_pump10_wd_dj_hz", "ws_pump10_wd_dj_A", "ws_pump10_wd_dj_B", "ws_pump10_wd_dj_C", "ws_pump10_Uab_out", "ws_pump10_Ia_out", "泵真空度10");


        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasDyWaterValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //1、2、5、6、7、8、9、10  有水、远控、就地、检修
        List<String> tagNames = Arrays.asList("ws_pump1_youshui", "ws_pump1_yf_czt", "ws_pump1_jd_czt", "ws_pump1_jx_czt",
                "ws_pump2_youshui", "ws_pump2_yf_czt", "ws_pump2_jd_czt", "ws_pump2_jx_czt",
                "ws_pump5_youshui", "ws_pump5_yf_czt", "ws_pump5_jd_czt", "ws_pump5_jx_czt",
                "ws_pump6_youshui", "ws_pump6_yf_czt", "ws_pump6_jd_czt", "ws_pump6_jx_czt",
                "ws_pump7_youshui", "ws_pump7_yf_czt", "ws_pump7_jd_czt", "ws_pump7_jx_czt",
                "ws_pump8_youshui", "ws_pump8_yf_czt", "ws_pump8_jd_czt", "ws_pump8_jx_czt",
                "ws_pump9_youshui", "ws_pump9_yf_czt", "ws_pump9_jd_czt", "ws_pump9_jx_czt",
                "ws_pump10_youshui", "ws_pump10_yf_czt", "ws_pump10_jd_czt", "ws_pump10_jx_czt");


        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasDyWaterTemp() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //高、低  水位、水温
        List<String> tagNames = Arrays.asList("ws_sensor_yewei_g", "ws_sensor_shuiwen_g", "ws_sensor_yewei_d", "ws_sensor_shuiwen_d");

        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasDyGasValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //环境瓦斯1、2
        List<String> tagNames = Arrays.asList("ws_sensor_H_CH41", "ws_sensor_H_CH42");

        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasDyFyValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //工况流量  瓦斯  负压  温度  一氧化碳    标况流量
        List<String> tagNames = Arrays.asList("ws_sensor_P_FLOW1", "ws_sensor_P_CH41", "ws_sensor_P_PRE1", "ws_sensor_P_TEM1", "ws_sensor_P_CO1", "ws_sensor_P_GKFLOW1",
                "ws_sensor_P_FLOW2", "ws_sensor_P_CH42", "ws_sensor_P_PRE2", "ws_sensor_P_TEM2", "ws_sensor_P_CO2", "ws_sensor_P_GKFLOW2",
                "ws_sensor_P_FLOW3", "ws_sensor_P_CH43", "ws_sensor_P_PRE3", "ws_sensor_P_TEM3", "ws_sensor_P_CO3", "ws_sensor_P_GKFLOW3",
                "ws_sensor_P_FLOW4", "ws_sensor_P_CH44", "ws_sensor_P_PRE4", "ws_sensor_P_TEM4", "ws_sensor_P_CO4", "ws_sensor_P_GKFLOW4");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasDyFMValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //出气阀、进气阀、水阀  关到位、开到位
        List<String> tagNames = Arrays.asList("ws_pump1_cqf_gdw", "ws_pump1_cqf_kdw", "ws_pump1_jqf_gdw", "ws_pump1_jqf_kdw", "ws_pump1_lqf_gdw", "ws_pump1_lqf_kdw",
                "ws_pump2_cqf_gdw", "ws_pump2_cqf_kdw", "ws_pump2_jqf_gdw", "ws_pump2_jqf_kdw", "ws_pump2_lqf_gdw", "ws_pump2_lqf_kdw",
                "ws_pump5_cqf_gdw", "ws_pump5_cqf_kdw", "ws_pump5_jqf_gdw", "ws_pump5_jqf_kdw", "ws_pump5_lqf_gdw", "ws_pump5_lqf_kdw",
                "ws_pump6_cqf_gdw", "ws_pump6_cqf_kdw", "ws_pump6_jqf_gdw", "ws_pump6_jqf_kdw", "ws_pump6_lqf_gdw", "ws_pump6_lqf_kdw",
                "ws_pump7_cqf_gdw", "ws_pump7_cqf_kdw", "ws_pump7_jqf_gdw", "ws_pump7_jqf_kdw", "ws_pump7_lqf_gdw", "ws_pump7_lqf_kdw",
                "ws_pump8_cqf_gdw", "ws_pump8_cqf_kdw", "ws_pump8_jqf_gdw", "ws_pump8_jqf_kdw", "ws_pump8_lqf_gdw", "ws_pump8_lqf_kdw",
                "ws_pump9_cqf_gdw", "ws_pump9_cqf_kdw", "ws_pump9_jqf_gdw", "ws_pump9_jqf_kdw", "ws_pump9_lqf_gdw", "ws_pump9_lqf_kdw",
                "ws_pump10_cqf_gdw", "ws_pump10_cqf_kdw", "ws_pump10_jqf_gdw", "ws_pump10_jqf_kdw", "ws_pump10_lqf_gdw", "ws_pump10_lqf_kdw");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> getDyDpGasValueList() {
        return gasDrainagePumpRoomMapper.getDyDpGasValueList();
    }

    @Override
    public List<GasDrainagePumpRoom> gasChFyValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //  瓦斯 温度 负压  一氧化碳 标况流量 工况流量
        List<String> tagNames = Arrays.asList("高负压总管管道瓦斯", "高负压总管管道温度", "高负压总管管道压力", "高负压总管管道一氧化碳", "高负压总管管道标况流量", "高负压总管管道工况流量",
                "低负压总管管道瓦斯", "低负压总管管道温度", "低负压总管管道压力", "低负压总管管道一氧化碳", "低负压总管管道标况流量", "低负压总管管道工况流量");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasChGdfyValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        List<String> tagNames = Arrays.asList("1#泵电机前轴温度", "1#泵电机后轴温度", "1#泵电机A相温度", "1#泵电机B相温度", "1#泵电机C相温度", "1#电压", "1#电流", "1#泵体前轴温度", "1#泵体后轴温度",
                "2#泵电机前轴温度", "2#泵电机后轴温度", "2#泵电机A相温度", "2#泵电机B相温度", "2#泵电机C相温度", "2#电压", "2#电流", "2#泵体前轴温度", "2#泵体后轴温度",
                "3#泵电机前轴温度", "3#泵电机后轴温度", "3#泵电机A相温度", "3#泵电机B相温度", "3#泵电机C相温度", "3#电压", "3#电流", "3#泵体前轴温度", "3#泵体后轴温度",
                "4#泵电机前轴温度", "4#泵电机后轴温度", "4#泵电机A相温度", "4#泵电机B相温度", "4#泵电机C相温度", "4#电压", "4#电流", "4#泵体前轴温度", "4#泵体后轴温度");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasChWaterTemp() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //高、低  水位、水温
        List<String> tagNames = Arrays.asList("高位水池水位", "高位水池水温", "低位水池水位", "低温水池水温");

        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasChFMValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //出气阀、进气阀、水阀  关到位、开到位
        List<String> tagNames = Arrays.asList("1#泵出气阀关到位", "1#泵出气阀开到位", "1#泵进气阀关到位", "1#泵进气阀开到位", "1#泵冷却水阀关到位", "1#泵冷却水阀开到位",
                "2#泵出气阀关到位", "2#泵出气阀开到位", "2#泵进气阀关到位", "2#泵进气阀开到位", "2#泵冷却水阀关到位", "2#泵冷却水阀开到位",
                "3#泵出气阀关到位", "3#泵出气阀开到位", "3#泵进气阀关到位", "3#泵进气阀开到位", "3#泵冷却水阀关到位", "3#泵冷却水阀开到位",
                "4#泵出气阀关到位", "4#泵出气阀开到位", "4#泵进气阀关到位", "4#泵进气阀开到位", "4#泵冷却水阀关到位", "4#泵冷却水阀开到位");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasChWaterValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //有水、远控、就地、检修
        List<String> tagNames = Arrays.asList("1#缺水信号", "1#泵冷却水阀远控", "1#就地模式", "1#检修模式",
                "2#缺水信号", "2#泵冷却水阀远控", "2#就地模式", "2#检修模式",
                "3#缺水信号", "3#泵冷却水阀远控", "3#就地模式", "3#检修模式",
                "4#缺水信号", "4#泵冷却水阀远控", "4#就地模式", "4#检修模式");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> gasChBfyValueList() {
        List<GasDrainagePumpRoom> gasDrainagePumpRooms = gasDrainagePumpRoomMapper.getAll();

        //泵负压
        List<String> tagNames = Arrays.asList("1#泵负压", "2#泵负压", "3#泵负压", "4#泵负压");
        List<GasDrainagePumpRoom> filteredList = gasDrainagePumpRooms.stream()
                .filter(room -> tagNames.contains(room.getTagName()))
                .collect(Collectors.toList());

        return filteredList;
    }

    @Override
    public List<GasDrainagePumpRoom> getChDpGasValueList() {
        return gasDrainagePumpRoomMapper.getChDpGasValueList();
    }
}
